package com.yibo.support.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface YBProcess {

    public static final String YB_INPUT = "yibo-input";

    public static final String YB_OUTPUT = "yibo-output";

    @Input(YBProcess.YB_INPUT)
    SubscribableChannel input();


    @Output(YBProcess.YB_OUTPUT)
    MessageChannel output();
}
